package com.qf.business.redenvlopes.task;

import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.stereotype.Component;

/**
 * 定时任务的任务处理器
 * author Ken
 * create_time 2022/12/7
 */
@Component
public class TimeTaskHandler {

    @XxlJob("redback")
    public void redback(){
//        //10W
//        int shardIndex = XxlJobHelper.getShardIndex();
//        int shardTotal = XxlJobHelper.getShardTotal(); //3台机器
//
//        //从数据库中查询过期红包的总量
//        int count = 10;//10条数据
//        //每台机器要处理的数量
//        int actionCount = count / shardTotal; //每台机器要处理3条数据
//        //当前机器要处理的数据范围
//        if(shardIndex < shardTotal - 1) {
//            //(shardIndex * actionCount), actionCount
//            // 0号机器的范围：0~2
//            // 1号机器的范围：3~5
//        } else {
//            //(shardIndex * actionCount), end
//            // 2号机器的范围：6~9
//        }

//        System.out.println("执行红包回退的任务.....机器下标：" + shardIndex + " 总执行器数量:" + shardTotal);

        System.out.println("执行红包回退的任务.....");

        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        System.out.println("[执行红包回退的任务完成.....]");
    }
}
